package com.SparkCore.framwork.common

import com.SparkCore.framwork.util.EnvUtil
import org.apache.spark.rdd.RDD

trait TDao {
  def readFile(path: String): RDD[String] = {
    //1、读取文件，获取一行一行的数据
    EnvUtil.take().textFile(path)
  }
}
